package com.syf.rocker;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.context.annotation.Configuration;


/**
 * 【3】开启我们的Stream的开发：
 *          绑定消息队列(消息源)，将其设为 配置类 -> 即: 可注入其他类中,获取到消息源对象 Sink和Source
 *              Source 准备消息源，发送到队列
 *              Sink 监听到队列消息 @Input("order_in") 进行处理
 */
@Configuration
@EnableBinding(value = {Sink.class,Source.class})    //绑定消息源
public class RocketStreamConfig {
}
